package com.tpc.wdt.task;

import com.tpc.wdt.service.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class Task {

    @Autowired
    private GoodsPush goodsPush;

    @Autowired
    private JoinInPush joinInPush;

    @Autowired
    private JoinOutPush joinOutPush;

    @Autowired
    private TrInQuery trInQuery;

    @Autowired
    private TrOutQuery trOutQuery;

    @Autowired
    private TrOutQueryMidFive trOutQueryMidFive;

    @Scheduled(cron = "${wdt.goodstask}") // 每5秒执行一次
    public void doGoodsPlus() {
        // 执行你的任务逻辑
        for(int i=0;i<21;i++){
            log.info("同步商品资料开始-----");
            goodsPush.goodsPush();
            log.info("同步商品资料结束-----");
        }

    }

    @Scheduled(cron = "${wdt.joinintask}") // 每5秒执行一次
    public void doJoinInPlus() {
        // 执行你的任务逻辑
        for(int i=0;i<21;i++) {
            log.info("同步入库上传开始-----");
            joinInPush.joinInPush();
            log.info("同步入库上传结束-----");
        }
    }

    @Scheduled(cron = "${wdt.joinouttask}") // 每5秒执行一次
    public void doJoinOutPlus() {
        // 执行你的任务逻辑
        for(int i=0;i<21;i++) {
            log.info("同步出库上传开始-----");
            joinOutPush.joinOutPush();
            log.info("同步出库上传结束-----");
        }
    }

    @Scheduled(cron = "${wdt.trintask}") // 每5秒执行一次
    public void doTrInPlus() {
//        // 执行你的任务逻辑
//        log.info("同步退货下载开始-----");
//        trInQuery.trInQuery();
//        log.info("同步退货下载结束-----");
    }

    @Scheduled(cron = "${wdt.trouttask}") // 每5秒执行一次
    public void doTrOutPlus() {
        // 执行你的任务逻辑
        log.info("同步出库下载开始-----");
        trOutQuery.trOutQuery();
        log.info("同步出库下载结束-----");
    }

    @Scheduled(cron = "${wdt.trouttasktwo}") // 每5秒执行一次
    public void doTrOutPlusTwo() {
        // 执行你的任务逻辑
        log.info("同步出库下载开始-----");
        trOutQuery.trOutQuery();
        log.info("同步出库下载结束-----");
    }

    @Scheduled(cron = "${wdt.trouttaskmidfive}") // 每5秒执行一次
    public void doTrOutPlusTwoMidFive() {
        // 执行你的任务逻辑
        log.info("同步出库下载开始-----");
//        trOutQuery.trOutQuery();
        trOutQueryMidFive.trOutQueryMidFive();
        log.info("同步出库下载结束-----");
    }


}
